org.springframework.test.web.reactive.server

Class WiretapConnector.WiretapClientHttpRequest

java.lang.Object

org.springframework.http.client.reactive.ClientHttpRequestDecorator

org.springframework.test.web.reactive.server.WiretapConnector.WiretapClientHttpRequest

All Implemented Interfaces:

ClientHttpRequest, HttpMessage, ReactiveHttpOutputMessage

Enclosing class:

WiretapConnector

private static class WiretapConnector.WiretapClientHttpRequest
extends ClientHttpRequestDecorator

ClientHttpRequestDecorator that intercepts and saves the request body.

Field Summary

Fields

Modifier and Type	Field and Description
private <any>	body
private DataBuffer	buffer

Constructor Summary

Constructors

Constructor and Description
WiretapClientHttpRequest(ClientHttpRequest delegate)

Method Summary

Modifier and Type	Method and Description
<any>	getContent() Return a "promise" with the request body content written to the server.
private void	handleError(java.lang.Throwable ex)
private void	handleOnComplete()
private void	handleOnNext(DataBuffer buffer)
<any>	setComplete() Indicate that message handling is complete, allowing for any cleanup or end-of-processing tasks to be performed such as applying header changes made via HttpMessage.getHeaders() to the underlying HTTP message (if not applied already).
<any>	writeAndFlushWith(<any> publisher) Use the given Publisher of Publishers to write the body of the HttpOutputMessage to the underlying HTTP layer, flushing after each Publisher<DataBuffer>.
<any>	writeWith(<any> publisher) Use the given Publisher to write the body of the message to the underlying HTTP layer.

Methods inherited from class org.springframework.http.client.reactive.ClientHttpRequestDecorator

beforeCommit, bufferFactory, getCookies, getDelegate, getHeaders, getMethod, getURI, isCommitted, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

buffer

private final DataBuffer buffer

body

private final <any> body

Constructor Detail

WiretapClientHttpRequest

public WiretapClientHttpRequest(ClientHttpRequest delegate)

Method Detail

getContent

public <any> getContent()

Return a "promise" with the request body content written to the server.

writeWith

public <any> writeWith(<any> publisher)

Description copied from interface: ReactiveHttpOutputMessage

Use the given Publisher to write the body of the message to the underlying HTTP layer.

Specified by:

writeWith in interface ReactiveHttpOutputMessage

Overrides:

writeWith in class ClientHttpRequestDecorator

Parameters:

publisher - the body content publisher

Returns:

a Mono that indicates completion or error

writeAndFlushWith

public <any> writeAndFlushWith(<any> publisher)

Description copied from interface: ReactiveHttpOutputMessage

Use the given Publisher of Publishers to write the body of the HttpOutputMessage to the underlying HTTP layer, flushing after each Publisher<DataBuffer>.

Specified by:

writeAndFlushWith in interface ReactiveHttpOutputMessage

Overrides:

writeAndFlushWith in class ClientHttpRequestDecorator

Parameters:

publisher - the body content publisher

Returns:

a Mono that indicates completion or error

setComplete

public <any> setComplete()

Description copied from interface: ReactiveHttpOutputMessage

Indicate that message handling is complete, allowing for any cleanup or end-of-processing tasks to be performed such as applying header changes made via HttpMessage.getHeaders() to the underlying HTTP message (if not applied already).

This method should be automatically invoked at the end of message processing so typically applications should not have to invoke it. If invoked multiple times it should have no side effects.

Specified by:

setComplete in interface ReactiveHttpOutputMessage

Overrides:

setComplete in class ClientHttpRequestDecorator

Returns:

a Mono that indicates completion or error

handleOnNext

private void handleOnNext(DataBuffer buffer)

handleError

private void handleError(java.lang.Throwable ex)

handleOnComplete

private void handleOnComplete()